import pymysql
# 创建一个数据库连接对象
# (127.0.0.1)
db=pymysql.connect('localhost',"root",'123456','woniu_atm_test',charset='utf8')
#创建游标对象
cur=db.cursor()
#执行sql语句
sql='''create table history(
hid int primary key ,
username varchar(20) ,
record varchar(100)
#foreign key (username) references user_info(username)
)engine=Innodb default charset="utf8"
'''
#插入数据
# sql="insert into user_info values(1,'张三',123456,'18782935700',88888),(2,'李四',234567,'18782935701',32000)"
# sql="update user_info set passwd='xiaoming' where username='李四'"



#sql="select * from user_info "
#sql="drop table user_info "
# sql='update '
cur.execute(sql)
#提交事务
db.commit()
#查询数据（需要特别注意，查询结果需要重新获取）
# result=cur.fetchall()
# print(result)
# result1=cur.fetchmany(4)#获取指定数量的元祖，括号里面是查询记录的条数
# print(result1)
#关闭对象
cur.close()
db.close()
#创建一个表格，一定要先连接数据库

#针对增删改都可以
def db_operation(sql):
    db=pymysql.connect("localhost",'root','123456','woniu_atm_tset',charset='utf8')
    cur=db.cursor()
    cur.execute(sql)
    db.commit()
    cur.close()
    db.close()
# db_operation()

#针对查询语句
def db_queryone(sql):
    db=pymysql.connect("localhost",'root','123456','woniu_atm_tset',charset='utf8')
    cur=db.cursor()
    cur.execute(sql)
    db.commit()
    result=cur.fetchone()
    cur.close()
    db.close()
    return result
#db_operation()


#高级版本
def create_object():
    db = pymysql.connect("localhost", 'root', '123456', 'woniu_atm_tset', charset='utf8')
    cur = db.cursor()
    return db,cur

# 针对增删改都可以用
def db_operation(sql):
    db,cur=create_object()
    cur.execute(sql)
    db.commit()
    cur.close()
    db.close()


